package com.yanggu.bigdata.realtime.app

import com.yanggu.bigdata.realtime.bean.TableProcess
import org.apache.flink.api.common.state.MapStateDescriptor

case object BroadcastObject {

  val tableProcessMapStateDescriptor = new MapStateDescriptor("TableProcess Map State Descriptor", classOf[(String, String)], classOf[TableProcess])

}
